package personal.wang.handler;

import io.netty.channel.ChannelHandlerContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import personal.wang.abs.AbstractMessageHandler;
import personal.wang.enm.TaskStatus;
import personal.wang.manager.RecordGeneratorManager;
import personal.wang.message.Message;

/**
 * @className: ACKHandler
 * @Description:
 * @Author: wangyifei
 * @Date: 2025/2/24 15:25
 */
public class ACKHandler extends AbstractMessageHandler {
    private static Logger logger = LoggerFactory.getLogger(ACKHandler.class);
    public RecordGeneratorManager recordGeneratorManager ;
    public ACKHandler(RecordGeneratorManager recordGeneratorManager){
        this.recordGeneratorManager = recordGeneratorManager;
    }

    @Override
    public void handler(Message message, ChannelHandlerContext ctx) {
        String host = "";
        recordGeneratorManager.ack(host , TaskStatus.STOP);
        super.handler(message, ctx);
    }
}
